package com.ydl.learning.flink.demo.pipeline.java;

import org.apache.flink.streaming.api.datastream.DataStream;

/**
 * 初始化当前处理任务，完成 Flink 启动前环境准备流数据的接入
 */
public interface Init<T> extends BaseProcedure {

  /**
   *
   */
  DataStream<T> init();

}